package com.fulu.game.bigdata.realtime.entity

import java.util

import scala.beans.BeanProperty

class Source extends Serializable {

  @BeanProperty var tableName: String = _
  @BeanProperty var tableType: String = "kafka"
  @BeanProperty var hiveTableName: String = _
  @BeanProperty var kafkaTopic: String = _
  @BeanProperty var kafkaGroup: String = _
  @BeanProperty var isCanalTable: Boolean = false
  @BeanProperty var isFromBeginning:Boolean = false
  @BeanProperty var kafkaStrategy: String = _
  @BeanProperty var eventTimeField: String = _
  @BeanProperty var watermark: Long = 1L
  @BeanProperty var fields: util.List[Field] = _

}
